package com.pangu.mq.kafka.handler;

import com.pangu.mq.Message;

/**
 * @author Linbizhao
 * @description: 上行消息处理器
 * @since 2023/11/23 15:35
 */
public interface UpstreamMessageHandler {

    /**
     * 消息处理方法
     *
     * @param var1
     */
    String handeMessage(Message var1);
}
